Public Function New( _
   ByVal process As Action(Of T), _
   ByVal nThreads As Integer _
)

public WorkQueue<T>( 
   Action<T> process,
   int nThreads
)

int[] counter = new int[1];
using (WorkQueue<int[]> worker = new WorkQueue<int[]>(ProcessOne, Math.Max(2, Environment.ProcessorCount)))
{
    for (int i = 0; i < 1000; i++)
        worker.Enqueue(counter);
    worker.Complete(false, 10);
}
Assert.AreNotEqual(0, counter[0]);

Dim counter As Integer() = New Integer(1) {}
Using worker As New WorkQueue(Of Integer())(ProcessOne, Math.Max(2, Environment.ProcessorCount))
    Dim i As Integer = 0
    While i < 1000
        worker.Enqueue(counter)
        System.Math.Max(System.Threading.Interlocked.Increment(i),i - 1)
    End While
    worker.Complete(False, 10)
End Using
Assert.AreNotEqual(0, counter(0))